package top.fullj.actor.mq;

public interface Subscriber<T> {

    void subscribe(Fiber fiber, Action<T> action);

}
